package com.tyc.flink.guigu.chapter05;

import org.apache.flink.api.common.functions.RichFlatMapFunction;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.util.Collector;

/**
 * 富函数最佳实践
 *
 * @author tyc
 * @version 1.0
 * @date 2022-11-22 10:40:58
 */
public class MyFlatMap<IN, OUT> extends RichFlatMapFunction<IN, OUT> {
    @Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
    }

    @Override
    public void flatMap(IN in, Collector<OUT> out) throws Exception {

    }

    @Override
    public void close() throws Exception {
        super.close();
    }


}
